package mr;

/*
    方法二：
        1、将大文件进行分割，成一个个小文件
        2、利用多线程进行处理，一个线程处理一个小文件
        3、将处理结果存入新的文件中
        4、



 */

import java.io.File;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class TestMap2 {

    public static void main(String[] args) {

        //获取文件列表
        File file = new File("F:\\数加\\代码\\nanshan\\split");
        File[] files = file.listFiles();

        //多线程连接池（线程池）
            ExecutorService executorService = Executors.newFixedThreadPool(files.length);


        int flag=0;
        for (File f : files) {

            MapThread mapThread = new MapThread(f,flag);
            executorService.submit(mapThread);
            flag++;

        }
        executorService.shutdown();


    }

}
